放入|教室_onvif协议+高性能rtspclient打通大屏投屏协议

篇首语：本文由编程笔记#小编为大家整理，主要介绍了onvif协议+高性能rtspclient打通大屏投屏协议相关的知识，希望对你有一定的参考价值。

  1.1 onvif简述和作用

a) 搜索列表
onvif协议本身是一个非常好的协议&＃xff0c;帮助打通网内所有视频&＃xff0c;搜索&＃xff0c;播放和控制都是可以的。
b) 如何搜索
使用多播协议&＃xff0c;以前写过很多多播的文章可以看&＃xff0c;读者可以查看我其他文章&＃xff0c;我是使用多播协议&＃xff0c;因为正好&＃xff0c;搜索所有大屏也需要使用多播协议&＃xff0c;例如ssdp协议&＃xff0c;而实际上onvif使用的是多播和soap&＃xff0c;打通的流程过程就是同时搜索大屏和onvif&＃xff0c;将两种设备放入到各自的列表&＃xff0c;
c) 融合
这里又有另外一种模式了&＃xff0c;就是我们的客户希望大屏作为一个融合过后的投屏&＃xff0c;而不是一个一个地投上去&＃xff0c;毕竟&＃xff0c;投屏协议同时只支持一路视频&＃xff0c;那么如何做呢&＃xff0c;以下就是做法

  1.2 制作高性能rtspclient

为什么要rtspclient&＃xff0c;因为onvif协议需要&＃xff0c;抓住设备列表以后获取协议地址&＃xff0c;然后开始做融合&＃xff0c;问题是性能&＃xff0c;rtsp拉流是比较耗性能和线程的&＃xff0c;所以如果使用其他比如ffmpeg或者live555 等不符合要求。
任何高性能的客户端只能自己制作&＃xff0c;使用单一进程联结多路&＃xff0c;或者使用多进程联结多路&＃xff0c;这个需要指挥调度&＃xff0c;问题是我们需要视频融合做mcu&＃xff0c;所以&＃xff0c;使用单一进程是最好的&＃xff0c;同时联结9路画到一个虚拟屏幕里&＃xff0c;硬件解码&＃xff0c;再重新硬件进行一路融合编码&＃xff0c;发送到服务器,以下是rtspclient 伪代码

int options( sock and string)

cout << &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;<<"OPTIONS"<<&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; << endl;
char sendBuf[2048];
snprintf(sendBuf, 1024,
"OPTIONS rtsp://1.1.1.1:554/Streaming/Channels/101?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 2\\r\\n"
"User-Agent: qianbo/3.0.12 (18091589062)\\r\\n"
"\\r\\n");
//printf("sendBuf :\\n%s\\n", sendBuf);
sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));
return 0;

void describe(sock and string)

//发送describe返回401 安全需要认证机制
cout << &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;<<"DESCRIBE"<<&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; << endl;
char sendBuf[2048];
snprintf(sendBuf, 2048,
"DESCRIBE rtsp://1.1.1.1:554/Streaming/Channels/101?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 3\\r\\n"
"User-Agent: qianbo/1.1.1 (18091589062)\\r\\n"
"Accept: application/sdp\\r\\n"
"\\r\\n");
//printf("sendBuf :\\n%s\\n", sendBuf);
sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));
return 0;

int describe_authorization(sock and address, char *realm, char *nonce, const char *response)

//返回401时需要客户端认证
cout << "DESCRIBE_AUTHORIZATION" << endl;
char sendBuf[2048];
snprintf(sendBuf, 2048,
"DESCRIBE rtsp://1.1.1.1:554/Streaming/Channels/101?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 4\\r\\n"
"Authorization: Digest username&＃61;\\"admin\\", realm&＃61;\\"%s\\", nonce&＃61;\\"%s\\", uri&＃61;\\"rtsp://192.168.8.250:554/Streaming/Channels/101?transportmode&＃61;unicast&profile&＃61;Profile_1\\", response&＃61;\\"%s\\"\\r\\n"
"User-Agent: qianbo/1.1.1 (18091589062)\\r\\n"
"Accept: application/sdp\\r\\n"
"\\r\\n",
realm, nonce, response);
return sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));


int setup(SOCKET& sock, sockaddr_in& sockAddr, char* realm, char* nonce, const char* response)

cout << "SETUP" << endl;
char sendBuf[2048];
snprintf(sendBuf, 2048,
"SETUP rtsp://192.168.8.250:554/Streaming/Channels/101/trackID&＃61;1?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 5\\r\\n"
"Authorization: Digest username&＃61;\\"admin\\", realm&＃61;\\"%s\\", nonce&＃61;\\"%s\\", uri&＃61;\\"rtsp://192.168.8.250:554/Streaming/Channels/101/\\", response&＃61;\\"%s\\"\\r\\n"
"User-Agent: qianbo/1.1.1 (18091589062)\\r\\n"
"Transport: RTP/AVP;unicast;client_port&＃61;23332-23333\\r\\n"
"\\r\\n",
realm, nonce, response);
return sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));

int play(SOCKET& sock, sockaddr_in& sockAddr, char* realm, char* nonce, const char* response, char *session)

cout << "PLAY" << endl;
char sendBuf[2048];
snprintf(sendBuf, 2048,
"PLAY rtsp://192.168.8.250:554/Streaming/Channels/101?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 6\\r\\n"
"Authorization: Digest username&＃61;\\"admin\\", realm&＃61;\\"%s\\", nonce&＃61;\\"%s\\", uri&＃61;\\"rtsp://192.168.8.250:554/Streaming/Channels/101/\\", response&＃61;\\"%s\\"\\r\\n"
"User-Agent: qianbo/1.1.1 (18091589062)\\r\\n"
"Session: %s\\r\\n"
"Range: npt&＃61;0.000-\\r\\n"
"\\r\\n",
realm, nonce, response, session);
return sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));

int teardown(SOCKET& sock, sockaddr_in& sockAddr, char* realm, char* nonce, const char* response, char* session)

cout <<"TEARDOWN"" << endl;
char sendBuf[2048];
snprintf(sendBuf, 2048,
"TEARDOWN rtsp://192.168.8.250:554/Streaming/Channels/101/?transportmode&＃61;unicast&profile&＃61;Profile_1 RTSP/1.0\\r\\n"
"CSeq: 7\\r\\n"
"Authorization: Digest username&＃61;\\"admin\\", realm&＃61;\\"%s\\", nonce&＃61;\\"%s\\", uri&＃61;\\"rtsp://192.168.8.250:554/Streaming/Channels/101/\\", response&＃61;\\"%s\\"\\r\\n"
"User-Agent: qianbo (18091589062)\\r\\n"
"Session: %s\\r\\n"
"\\r\\n",
realm, nonce, response, session);
return sendto(sock, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockAddr, sizeof(sockAddr));


1.3 onvif 探针

需要向网络中发送soap包探听

int sendProbe(int fd,const char *uuid,const char *types)

int r;
struct sockaddr_in srv;
memset( &srv, 0, sizeof(struct sockaddr_in) );
srv.sin_family &＃61; AF_INET;
srv.sin_port &＃61; htons(PUERTO);
srv.sin_addr.s_addr &＃61; inet_addr(GRUPO);

char Probe[4096];
sprintf(Probe,""\\
""\\
""\\
"%s"\\
"urn:schemas-xmlsoap-org:ws:2005:04:discovery"\\
"http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe"\\
""\\
""\\
""\\
"%s"\\
""\\
""\\
""\\
"\\r\\n",uuid,types);
if( (r &＃61; sendto(fd, Probe, strlen(Probe), 0, (struct sockaddr *)&srv, sizeof(srv))) < 0 )

cout<<"sendto failed"<<endl;
closesocket(fd);
return -1;

return 0;


2 投屏协议

读者可以参考我的其他投屏协议的文章&＃xff0c;实际上投屏协议需要一个服务器&＃xff0c;大部分大屏是支持各类协议&＃xff0c;我们制作通用的rtsp服务器就行&＃xff0c;使用tcp方式发送rtp&＃xff0c;这样防止服务器在外网&＃xff0c;而大屏在内网。
服务器在外网的时候有一个好处&＃xff0c;就是可以将内网的视频传送到另外一个地方的大屏中&＃xff0c;这是可以的。但是需要一个寻找大屏和通知大屏的内网代理&＃xff0c;这个以后说。

需要使用ssdp等协议发送刚才融合的视频&＃xff0c;把地址给到大屏&＃xff0c;如果同时投屏到多个&＃xff0c;那么多个大屏会同时播放融合的视频&＃xff0c;这种方案还可以使用到教学种&＃xff0c;可以将教学视频同时投放到多个教室。

后面的几节会具体讲述各个过程的具体实现&＃xff0c;未完待续…